package com.sf.bank.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.jms.Destination;

/**
 * 发送消息
 * 编写Controller，发送消息
 * 我们没有安装ActiveMQ，为什么可以使用？因为Spring Boot 内置了ActiveMQ 的服务，
 * 所以我们不用单独启动也可以实现消息的发送和接收。
 */
@Controller
@RequestMapping("queue")
public class QueueController {
    //注入发送消息的对象
    @Autowired
    private JmsTemplate jmsTemplate;

    //注入消息队列
    @Autowired
    private Destination destination;

    //编写发送消息的方法
    @RequestMapping("send/{message}")
    public String send(@PathVariable String message) {
        this.jmsTemplate.convertAndSend(destination, message);
        return "消息发送成功!消息内容：" + message;
    }
}
